// Copyright (C) 2012 Yury Bychenkov (http://bychenkov.com).
// All rights reserved.
//
// Redistribution and use in source and binary forms, with or without
// modification, are permitted provided that the following conditions are
// met:
//
//  - Redistributions of source code must retain the above copyright
// notice, this list of conditions and the following disclaimer.
//  - Redistributions in binary form must reproduce the above
// copyright notice, this list of conditions and the following disclaimer
// in the documentation and/or other materials provided with the
// distribution.
//  - Neither the name of Yury Bychenkov nor the names of its
// contributors may be used to endorse or promote products derived from
// this software without specific prior written permission.
//
// THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS
// "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT
// LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR
// A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT
// OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
// SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT
// LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
// DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
// THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
// (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE
// OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.

#ifndef concurrent_h
#define concurrent_h

#include "common.h"

class LatchLock {
public:
    LatchLock();
    ~LatchLock();

    void lock();
    void unlock();

private:
    void operator=(const LatchLock&) {};

private:
#ifdef WINDOWS64
    CRITICAL_SECTION criticalSection;
#endif

#ifdef POSIX64
    volatile uint32 locked;
#endif
};

class ReadWriteLatch {
public:
    ReadWriteLatch();
    ~ReadWriteLatch();

    void readLock();
    void readUnlock();

    void writeLock();
    void writeUnlock();

private:
    void operator=(const ReadWriteLatch&) {};

private:
    LatchLock lock;
    volatile int readLockCount;
    volatile int awaitingWriterCount;
};

template <typename Lock>
class LockGuard {
public:
	explicit LockGuard(Lock& lock);
	~LockGuard();
	
private:
	Lock& lock;
};

class Thread {
public:
	Thread();
	~Thread();

	void start();
	void join();
	void interrupt();
	bool isInterrupted();

	static void sleep(uint32 millis);
	static void yield();

protected:
	virtual void run() = 0;

private:
#ifdef WINDOWS64
    static unsigned WINAPI threadProc(void* threadObject);

	HANDLE threadHandle;
#endif

#ifdef POSIX64
    static void* threadProc(void* threadObject);

    pthread_t threadHandle;
#endif


	LatchLock lock;
	volatile bool interrupted;

};

template <typename T>
class SafeArray {
public:
	SafeArray();
	SafeArray(const vector<T>& data);
	SafeArray(const SafeArray& data);

	uint getCount() const;
	uint add(const T& e);
	T operator[](uint index) const;
	bool get(uint index, T& e) const;
	bool set(uint index, const T& e);
	bool getLast(T& e) const;

private:
 	mutable LatchLock lock;
 	vector<T> data;
};

#include "concurrent.hpp"

#endif // concurrent_h
